﻿using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
using System.Xml.Linq;

namespace 消费者
{
    class Program
    {
        static void Main(string[] args)
        {
            IConnectionFactory factory = new ConnectionFactory//创建连接工厂对象
            {
                HostName = "192.168.137.101",//IP地址
                Port = 5672,//端口号
                VirtualHost = "jet-test",
                UserName = "admin",//用户账号
                Password = "123456"//用户密码
            };
            try
            {
                IConnection con = factory.CreateConnection();//创建连接对象
                IModel channel = con.CreateModel();//创建连接会话对象
                string queueName = "queue1";  //声明一个队列
                channel.QueueDeclare(
                      queue: queueName,//消息队列名称
                      durable: false,//是否持久化,true持久化,队列会保存磁盘,服务器重启时可以保证不丢失相关信息。
                      exclusive: false,//是否排他,true排他的,如果一个队列声明为排他队列,该队列仅对首次声明它的连接可见,并在连接断开时自动删除.
                      autoDelete: false//是否自动删除。true是自动删除。自动删除的前提是：致少有一个消费者连接到这个队列，之后所有与这个队列连接的消费者都断开时,才会自动删除.
                                       //arguments: arg //一般设置为null，设置队列的一些其它参数,比如存活时间
                   );
                //var bas = channel.BasicGet("queue1",false);
                //channel.BasicAck(bas.DeliveryTag,false);

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                   
                    
                    var message =ea.Body;//接收到的消息
                    Console.WriteLine("接收到消息为:" + Encoding.UTF8.GetString(message.ToArray()));
                   
                };
                //消费者开启监听
                channel.BasicConsume(queueName, true, consumer);
                Console.ReadKey();
                channel.Dispose();
                con.Close();
            }
            catch (Exception ex)
            {

                throw;
            }

        }
    }
}
